package com.Reactor3参考文档.Observable工具操作符;

import reactor.core.publisher.Mono;

public class Subscribe {

	// 通过subscribe()方法添加相应的订阅逻辑
	public static void main(String[] args) {
		// 我们得到一个100，同时也获取了一个IllegalStateException
		Mono.just(100).concatWith(Mono.error(new IllegalStateException())).subscribe(System.out::println, System.err::println);
		// 有时候我们不想直接抛出异常，而是采用一种容错策略返回一个默认值
		Mono.just(100).concatWith(Mono.error(new IllegalStateException())).onErrorReturn(0).subscribe(System.out::println, System.err::println);
	}

}
